package cn.microservices.cloud.system.web.controller;

import cn.microservices.cloud.system.service.stream.TestKafkaOut;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

@RestController
@RequestMapping("stream")
public class TestController {
    @Resource
    private TestKafkaOut kafkaOut;

    @RequestMapping("send")
    public String send(){
        kafkaOut.sendMessage();
        return "success";
    }
}
